9321dc73113ae19615536b93fc33eeb53a9fa88a,spring-cloud-function-task/src/main/java/org/springframework/cloud/function/task/TaskConfiguration.java,TaskConfiguration,commandLineRunner,#FunctionCatalog#,50

Before Change


				.lookupSupplier(properties.getSupplier());
		String functionName = properties.getFunction();
		Function<Flux<Object>, Flux<Object>> function = (functionName.indexOf(',') == -1)
				? registry.lookupFunction(functionName)
				: registry.composeFunction(
						StringUtils.commaDelimitedListToStringArray(functionName));
		final Consumer<Object> consumer = registry
				.lookupConsumer(properties.getConsumer());

After Change


				.lookupSupplier(properties.getSupplier());
		String functionName = properties.getFunction();
		Function<Flux<Object>, Flux<Object>> function = registry
				.lookupFunction(functionName);
		final Consumer<Object> consumer = registry
				.lookupConsumer(properties.getConsumer());
		final CountDownLatch latch = new CountDownLatch(1);